package com.alan.datasync.source;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Author: li_jl
 * @Description:
 * @Date: Created in 2020/6/8 4:38 下午
 */
public interface TestSink {
    /**
     * 渠道input_test
     */
    String INPUT_TEST = "input_test";

    /**
     * @return 输入测试
     */
    @Input(TestSink.INPUT_TEST)
    SubscribableChannel inputTest();
}
